package com.qit.prototype.flink.processor;

import com.qit.common.stream.ParallelSequenceProcessor;
import com.qit.prototype.flink.entity.MarketData;
import com.qit.prototype.flink.entity.Tick;

public class MarketDataConvertProcessor extends ParallelSequenceProcessor<Tick, MarketData>
		implements IMarketDataConvertProcessor {

	public MarketDataConvertProcessor(
			int parallelCount,
			IMarketDataConvertJob job) {
		super(parallelCount, job);
	}

}
